from airflow.patsnap.service.workflow_service import workflow_patch

data = {
    "content":{
        "nodes":[
            {
                "branches":[
                    {
                        "branchId":1,
                        "nextStateId":"64742395-ec75-4731-b0bf-af5d781c36bf",
                        "nextStateType":"end"
                    }
                ],
                "name":"spark_pi",
                "nodeId":2,
                "stateId":"552ffcfd-5d09-4c85-bd65-a0c352144977",
                "taskId":82,
                "type":"SPARK",
                "x":463,
                "y":23
            },
            {
                "branches":[

                ],
                "name":"spark_pi_2",
                "nodeId":2,
                "stateId":"64742395-ec75-4731-b0bf-af5d781c36bf",
                "taskId":91,
                "type":"SPARK",
                "x":461,
                "y":149
            }
        ]
    }
}

workflow_patch(46, data)
